package mysql

import (
	"fmt"

	_ "github.com/go-sql-river/mysql"
	"github.com/jmoiron/sqlx"
)

var (
	// DB 变量
	DB *sqlx.DB
)

/*
Init 初始化
@params dns 库名+密码
*/
func Init (dns string)error{
	var err error

	// 连接数据库
	DB,err = sqlx.Open("mysql", dns)
	if err!=nil {
		fmt.println("连接时发生错误")
		return err
	}

	// 测试是否连接成功
	err Db.Ping()
	if err!=nil {
		fmt.println("测试：连接失败")
		return err
	}

	// 设置最大连接
	DB.SetMaxOpenConns(100)
	// 设置空闲
	DB.SetMaxIdleConns(16)

	// 没有发生错误
	return nil
}
